package com.bfxy.test1;

import com.bfxy.disruptor.common.event.EventHandler;


public class Consumer1 implements EventHandler<Order>{

	public void onEvent(Order event, long sequence, boolean endOfBatch) throws Exception {
//		Thread.sleep(Integer.MAX_VALUE);
		System.err.println("消费者: " + event.getValue());
	}

}
